package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.ConnectorBinderConstant;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Service;

@Service("connectorProducerBinder")
public interface ConnectorProducerBinder {

    @Output(ConnectorBinderConstant.CONNECTOR_OUTPUT)
    MessageChannel connectorOutput();

    @Output(ConnectorBinderConstant.CONNECTOR_HISTORY_DATA_INIT_OUTPUT)
    MessageChannel connectorHistoryDataInitOutput();
}
